package com.qen.conditions.query;

import com.qen.common.SqlHelper;
import com.qen.conditions.ChainWrapper;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;

import java.util.List;
import java.util.Optional;

/**
 * 具有查询方法的接口
 *
 * @author licz
 * @data 2025年05月26日 8:48 AM
 */
public interface ChainQuery<T> extends ChainWrapper<T> {

    /**
     * 获取集合
     *
     * @return 集合
     */
    default List<T> list() {
        return execute(dao -> dao.selectList(getWrapper()));
    }

    /**
     * 获取集合
     *
     * @param page 分页条件
     * @return 集合记录
     *
     */
    default PageResult<T> list(PageRequest<T> page) {
        return execute(dao -> dao.selectList(page, getWrapper()));
    }

    /**
     * 获取单个
     *
     * @return 单个
     */
    default T one() {
        return execute(dao -> dao.selectOne(getWrapper()));
    }

    /**
     * 获取单个
     *
     * @return 单个
     * @since 1.0.0
     */
    default Optional<T> oneOpt() {
        return Optional.ofNullable(one());
    }

    /**
     * 获取 count
     *
     * @return count
     */
    default Long count() {
        return execute(dao -> SqlHelper.retCount(dao.selectCount(getWrapper())));
    }

    /**
     * 判断数据是否存在
     *
     * @return true 存在 false 不存在
     */
    default boolean exists() {
        return this.count() > 0;
    }

    /**
     * 获取分页数据
     *
     * @param page 分页条件
     * @return 分页数据
     */
    default <E extends PageRequest<T>> PageResult<T> page(E page) {
        return execute(dao -> dao.selectPage(page, getWrapper()));
    }

}
